package com.example.androidtest.demo3

import com.example.androidtest.demo.ServerThreadUtil
import java.io.InputStreamReader
import java.net.ServerSocket
import java.net.Socket

class NettyServer {
}

fun main(){
    val server = ServerSocket(8887) // 服务器端端口
    val flag = true // 定义标记，可以一直死循环
    while (flag) { // 通过标记判断循环
        Thread(MyRunable(server.accept())).start() // 启动线程
    }
    server.close() // 关闭服务器
}

class MyRunable(private val socket:Socket):Runnable{
    override fun run() {
        var inreader=InputStreamReader(socket.getInputStream())
        while (true){
            println(inreader.readText().trim())
            Thread.sleep(2000)
        }


     }
}